package publish

import (
	"gitee.com/fierce_wolf/go-fox-edge-common/commSql"
	"gitee.com/fierce_wolf/go-fox-edge-common/edgeEntity"
)

var (
	telemetryDVR *telemetryDeviceValuePublish
	telemetryDSR *telemetryDeviceSequencePublish
	event        *eventPublish
)

func init() {
	telemetryDVR = &telemetryDeviceValuePublish{}
	telemetryDSR = &telemetryDeviceSequencePublish{}
}

func Register() {
	// 注册数据库访问信息：后面它能够根据Entity的注册信息，获得数据库的相关访问信息
	commSql.Register(edgeEntity.Type.DeviceRecordEntity.Type())
	commSql.Register(edgeEntity.Type.DeviceValueRecordEntity.Type())
	commSql.Register(edgeEntity.Type.DeviceSequenceEntity.Type())
}
